# Celery 入口
from celery import Celery


# 为celery使用django配置文件进行配置
import os
if not os.getenv("DJANGO_SETTINGS_MODULE"):
    os.environ["DJANGO_SETTINGS_MODULE"] = "MeiDuo_Project.settings"


# 创建celery实例
celery_app = Celery("meiduo")

# 加载配置文件
celery_app.config_from_object("celery_tasks.config")

# 注册任务
celery_app.autodiscover_tasks(["celery_tasks.sms", "celery_tasks.email"])